package com.ahcloud.edas.common.kafka;

import org.apache.kafka.clients.consumer.ConsumerRecords;

/**
 * @program: edas-common
 * @description:
 * @author: YuKai Fan
 * @create: 2024/4/20 10:10
 **/
public interface AckManually<K, V> {

    /**
     * 消息ack
     * @param messages
     */
    void ack(ConsumerRecords<K, V> messages);
}
